e1b69bd548bf67913ba58ef45f8bd85e743e12ce,hbase-server/src/main/java/org/apache/hadoop/hbase/mapreduce/CopyTable.java,CopyTable,run,#String[]#,277
Before Change
String[] otherArgs = new GenericOptionsParser(getConf(), args).getRemainingArgs();
Job job = createSubmittableJob(getConf(), otherArgs);
if (job == null) return 1;
return job.waitForCompletion(true) ? 0 : 1;
}
}
After Change
String[] otherArgs = new GenericOptionsParser(getConf(), args).getRemainingArgs();
Job job = createSubmittableJob(otherArgs);
if (job == null) return 1;
if (!job.waitForCompletion(true)) {
LOG.info("Map-reduce job failed!");
if (bulkload) {
LOG.info("Files are not bulkloaded!");
}
return 1;
}
int code = 0;
if (bulkload) {
code = new LoadIncrementalHFiles(this.getConf()).run(new String[]{this.bulkloadDir.toString(),
this.dstTableName});
if (code == 0) {
// bulkloadDir is deleted only LoadIncrementalHFiles was successful so that one can rerun